package net.qiqbframework.persisthanding;

import net.qiqbframework.eventhandling.EventMessage;
import net.qiqbframework.tracing.Span;

public interface EventBusSpanFactory {

    Span createPublishEventSpan(EventMessage<?> eventMessage);


    Span createCommitEventsSpan();


    <T> EventMessage<T> propagateContext(EventMessage<T> eventMessage);
}
